import logging

from django.core.mail import send_mail

# 创建日志对象
from celery_tasks.celery_main import app

logger = logging.getLogger(__name__)


# 创建task任务队列 第一个用户需要发送邮件 第二个用户需要发送邮件
@app.task(name='send_mail_task')
def send_mail_task(email, html_message):
    try:
        res_email = send_mail(
            subject='HAOKE商城',
            message='',
            html_message=html_message,
            from_email=None,
            recipient_list=[email]
        )
    except Exception as e:
        logger.error(f'邮件发送异常[email:{email},message:{e}]')
    else:
        if res_email:
            logger.info(f'邮件发送成功[email:{email}]')
        else:
            logger.warning(f'邮件发送失败[emial:{email}]')
